<?php

namespace work_queues;
require_once __DIR__ . '/../vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;
class worker
{
    public function __construct()
    {
        self::worker();
    }

    public static function worker()
    {
        $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
        $channel = $connection->channel();
        /**
         * 生成一个队列
         * 1、队列名称
         * 2、队列里面的消息是否持久化（磁盘 - true），默认情况下，消息存储在内存中
         * 3、该队列是否只供一个消费者进行消费 是否进行消息共享，true 可以多个消费者消费，默认情况下不共享
         * 4、是否自动删除 最后一个消费者断开连接以后 该队列是否自动删除 true 自动删除，false 不删除
         * 5、其他参数
         */
        $channel->queue_declare('task_queue', false, true, false, false);

        echo ' [*] Waiting for messages. To exit press CTRL+C', "\n";

        $callback = function($msg){
            echo " [x] Received ", $msg->body, "\n";
            sleep(substr_count($msg->body, '.'));
            echo " [x] Done", "\n";
            $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
        };

        /**
         * 生成一个队列
         * 1、队列名称
         * 2、队列里面的消息是否持久化（磁盘 - true），默认情况下，消息存储在内存中
         * 3、该队列是否只供一个消费者进行消费 是否进行消息共享，true 可以多个消费者消费，默认情况下不共享
         */
        $channel->basic_qos(null, 1, null);

        /**
         * 生成一个队列
         * 1、队列名称
         * 2、交换机
         * 3、
         * 4、消费成功后是否要自动应答 true 代表自动应答 false 代表手动应答
         * 5、
         * 6、消费者未成功消费的回调
         * 7、消费者成功消费的回调
         */
        $channel->basic_consume('task_queue', '', false, false, false, false, $callback);

        while(count($channel->callbacks)) {
            $channel->wait();
        }

        $channel->close();
        $connection->close();
    }
}

new worker();